BrmTron Server/src/cz/brmlab/brmtron/server/BrmTronServerThread.java

   1 package cz.brmlab.brmtron.server;
   2
   3 import java.io.BufferedReader;
   4 import java.io.DataOutputStream;
   5 import java.io.InputStreamReader;
   6 import java.net.Socket;
   7 import java.util.Map;
   8 import java.util.Scanner;
   9 import java.util.Set;
  10
  11 public class BrmTronServerThread extends Thread {
  12
  13         private Socket sock;
  14         private int id;
  15         private Player player;
  16
  17
  18         public BrmTronServerThread(Socket sock, int id){
  19                 super("BrmTronServerThread");
  20                 this.sock = sock;
  21                 this.id = id;
  22                 this.player = new Player();
  23         }
  24
  25         @Override
  26         public void run() {
  27                 String s;
  28                 double[] loc = new double[2];
  29                 try {
  30                         DataOutputStream out = new DataOutputStream(sock.getOutputStream());
  31                         BufferedReader in = new BufferedReader(new InputStreamReader(sock.getInputStream()));
  32
  33                         player.setActive(true);
  34
  35                         while((s=in.readLine()) != null) {
  36                                 if(s.equalsIgnoreCase("die")){
  37                                         player.setActive(false);
  38                                 }
  39                                 if(s.equals("quit")) {
  40                                         break;
  41                                 }
  42                                 Scanner sc = new Scanner(s);
  43                                 for(int i=0;sc.hasNextDouble();i++) {
  44                                         loc[i] = sc.nextDouble();
  45                                 }
  46                                 player.setCoords(loc);
  47                                 BrmTronServer.updatePlayer(id, player);
  48                                 out.writeBytes(parsePlayers(BrmTronServer.getPlayers()));
  49
  50                         }
  51                         out.close();
  52                         in.close();
  53                         sock.close();
  54                 } catch(Exception e) {
  55                         System.err.println(e);
  56                 }
  57
  58         }
  59
  60         private String parsePlayers(Map<Integer, Player> players) {
  61                 String ret = new String();
  62                 Set<Integer> keys = players.keySet();
  63
  64                 for(int i: keys) {
  65                         double[] coords = players.get(i).getCoords();
  66                         boolean active = players.get(i).isActive();
  67                         ret += "ID: " + i + ", Long: " + coords[0] + ", Lat: " + coords[1] + ", Active: " + active + "\n";
  68                 }
  69
  70                 return ret;
  71         }
  72
  73 }